#ifndef __MQTT_JSON_H__
#define __MQTT_JSON_H__

#include <stdio.h>
#include <stdbool.h>
#include <stdlib.h>
#include <string.h>
#include "dp_pthread.h"
#include "MQTTClient.h"
#include "cJSON.h"
#include "list.h"
#include "shmem.h"
#include "MQTTClient.h"

#define ADDRESS "tcp://localhost:1883"
#define CLIENTID_P "ClientPub"
#define CLIENTID_S "ClientSub"
#define QOS 1
#define TIMEOUT 10000L
#define TOPIC_P "/app/data/up"
#define TOPIC_S "/app/data/down"




// MQTT客户端
extern MQTTClient client;


void MQTT_init();
void publishToQt(const char *payload);
void publishToAito(const char *payload);
#endif